<?php 

    require_once 'SqlHelper.class.php';

	class MessageService{
		
		//添加信息到数据库中
		function addMessage($sender,$getter,$con){
			
			//组织一个sql
			$sql="INSERT INTO message (sender,getter,content,sendTime)values('$sender','$getter','$con',now())";
			//file_put_contents("d:/mylog.log","sql=".$sql."\r\n",FILE_APPEND);
	
				
				
				//创建一个SqlHelper对象
				$sqlHelper=new SqlHelper();
				
				return $sqlHelper->execute_dml($sql);			
		}
		
		//获取数据，并把数据组装好返回给客户端（聊天室）
		function getMessage($getter,$sender){
			
			$sql = "select * from message where getter = '$getter' and sender = '$sender' and isGet = 0";
			
			//调试找错，看sql是否有错
			//file_put_contents("d:/mylog.log",$sql."\r\n",FILE_APPEND);
	
	
				//创建一个SqlHelper对象
				$sqlHelper = new SqlHelper();
				$array = $sqlHelper -> excute_dql2($sql);
				
				//返回给库客户端的信息格式XML
				//$messageInfo = "<meses><mesid>1<mesid><mesid><sender>张三</sender>
				//<getter>宋江</getter><cons>内容</cons><sendTime>2014-12-11</sendTime></meses>"
				
				//拼接xml格式信息
				$messageInfo = "<meses>";
				for($i=0 ; $i<count($array) ; $i++){
				
					$row = $array[$i];
					$messageInfo.="<mesid>{$row['id']}</mesid>
					<sender>{$row['sender']}</sender><getter>{$row['getter']}</getter>
					<con>{$row['content']}</con><sendTime>{$row['sendTime']}</sendTime>";
				
				}
				$messageInfo.="</meses>";		//<meses></meses>
				
				//输出日志
				file_put_contents("d:/mylog.log",$messageInfo."\r\n",FILE_APPEND);
				
				//更新一下isGet
				
				$sqlHelper -> close_connect();			
				
				return $messageInfo;
		}		
	}


